package com.cnebula.dataprocess.hive.job.serivce;

/**
 * hive client 服务
 *
 */
public interface HiveService {

	/**
	 * 全量新增数据
	 * @param dataFile sqoop导入数据的文件地址
	 * @param tableName 插入表名
	 * @return
	 */
	public void loadDataOverwrite(String taskId, String jobId, String dataFile, String tableName);
	
	/**
	 * 增量新增数据
	 * @param dataFile sqoop导入数据的文件地址
	 * @param tableName 插入表名
	 * @return
	 */
	public void loadData(String taskId, String jobId, String dataFile, String tableName);
	
	/**
	 * 数据查重
	 * @param tableName 查重表
	 * @param passColumn 查重列
	 * @return
	 */
	public void dataPass(String taskId, String jobId, String tableName, String passColumn);
	
	
	/**
	 * 数据清洗
	 * @param sql
	 * @return
	 */
	public void purge(String taskId, String jobId, String sql);
}
